package cn.gjxblog;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author gjx
 * @version v1.0
 * @Description
 * @date 2019/7/5 16:37
 */
public interface Barista {

    String OUTPUT_CHANNEL = "output_channel";

    @Output(Barista.OUTPUT_CHANNEL)
    MessageChannel logoutput();


    String INPUT_CHANNEL = "input_channel";

    @Input(Barista.INPUT_CHANNEL)
    SubscribableChannel loginput();


}
